def getcolumns(stream):
 pipe = Pipeline()
 pipe.append(ColumnsSelect())
 return pipe(stream)

def getcolumns ( stream ) : pipe = Pipeline ( ) pipe . append ( ColumnsSelect ( ) ) return pipe ( stream )
function that return the colums of a select query .