From ffd6675979f0d3f4ec248a1288f80267a9eae9f8 Mon Sep 17 00:00:00 2001
From: Jim Paris <jim@jtan.com>
Date: Mon, 8 Apr 2013 19:46:16 -0400
Subject: [PATCH] Remove outdated code

---
 src/filter.py | 8 --------
 1 file changed, 8 deletions(-)

diff --git a/src/filter.py b/src/filter.py
index 9df5d75..8c0a37e 100644
--- a/src/filter.py
+++ b/src/filter.py
@@ -281,14 +281,6 @@ class Filter(object):
         extractor = NumpyClient(self.src.url).stream_extract_numpy
         inserter = NumpyClient(self.dest.url).stream_insert_numpy_context
 
-        # Format output data.
-        formatter = lambda row: " ".join([repr(x) for x in row]) + "\n"
-
-        def batch(iterable, size):
-            c = itertools.count()
-            for k, g in itertools.groupby(iterable, lambda x: c.next() // size):
-                yield g
-
         for interval in self.intervals():
             print "Processing", self.interval_string(interval)
             with inserter(self.dest.path,