Skip to content

Commit

Permalink
flake 8
Browse files Browse the repository at this point in the history
  • Loading branch information
bmyerz committed Jul 1, 2014
1 parent 5c9bb14 commit d881a2f
Showing 1 changed file with 20 additions and 18 deletions.
38 changes: 20 additions & 18 deletions raco/grappalang.py
Original file line number Diff line number Diff line change
Expand Up @@ -106,8 +106,10 @@ def pipeline_wrap(ident, plcode, attrs):
auto end_%(ident)s = walltime();
auto runtime_%(ident)s = end_%(ident)s - start_%(ident)s;
VLOG(1) << "pipeline %(ident)s: " << runtime_%(ident)s << " s";
VLOG(1) << "timestamp %(ident)s start " << std::setprecision(15) << start_%(ident)s;
VLOG(1) << "timestamp %(ident)s end " << std::setprecision(15) << end_%(ident)s;
VLOG(1) << "timestamp %(ident)s start " << std::setprecision(15)\
<< start_%(ident)s;
VLOG(1) << "timestamp %(ident)s end " << std::setprecision(15)\
<< end_%(ident)s;
""")
code = timing_template % locals()

Expand Down Expand Up @@ -1012,22 +1014,22 @@ def __init__(self):

def opt_rules(self):
return [
# rules.removeProject(),
rules.CrossProduct2Join(),
rules.SimpleGroupBy(),
# SwapJoinSides(),
rules.OneToOne(algebra.Select, GrappaSelect),
rules.OneToOne(algebra.Apply, GrappaApply),
# rules.OneToOne(algebra.Scan,MemoryScan),
MemoryScanOfFileScan(),
# rules.OneToOne(algebra.Join, GrappaSymmetricHashJoin),
rules.OneToOne(algebra.Join, self.join_type),
rules.OneToOne(algebra.Project, GrappaProject),
rules.OneToOne(algebra.GroupBy, GrappaGroupBy),
# TODO: this Union obviously breaks semantics
rules.OneToOne(algebra.Union, GrappaUnionAll)
# rules.FreeMemory()
]
# rules.removeProject(),
rules.CrossProduct2Join(),
rules.SimpleGroupBy(),
# SwapJoinSides(),
rules.OneToOne(algebra.Select, GrappaSelect),
rules.OneToOne(algebra.Apply, GrappaApply),
# rules.OneToOne(algebra.Scan,MemoryScan),
MemoryScanOfFileScan(),
# rules.OneToOne(algebra.Join, GrappaSymmetricHashJoin),
rules.OneToOne(algebra.Join, self.join_type),
rules.OneToOne(algebra.Project, GrappaProject),
rules.OneToOne(algebra.GroupBy, GrappaGroupBy),
# TODO: this Union obviously breaks semantics
rules.OneToOne(algebra.Union, GrappaUnionAll)
# rules.FreeMemory()
]

def set_join_type(self, joinclass):
self.join_type = joinclass

0 comments on commit d881a2f

Please sign in to comment.