aboutsummaryrefslogtreecommitdiffstats
path: root/python/sandcrawler/workers.py
diff options
context:
space:
mode:
authorBryan Newbold <bnewbold@archive.org>2020-06-16 17:10:44 -0700
committerBryan Newbold <bnewbold@archive.org>2020-06-16 17:10:44 -0700
commit9df71395046d045d7f8b568a55de4ea000de8791 (patch)
treeca160903d63dca48a02706447a9003e7f369416d /python/sandcrawler/workers.py
parentb839dcb734805397b8bf611eb77942b9555f4915 (diff)
downloadsandcrawler-9df71395046d045d7f8b568a55de4ea000de8791.tar.gz
sandcrawler-9df71395046d045d7f8b568a55de4ea000de8791.zip
rename KafkaGrobidSink -> KafkaCompressSink
Diffstat (limited to 'python/sandcrawler/workers.py')
-rw-r--r--python/sandcrawler/workers.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/python/sandcrawler/workers.py b/python/sandcrawler/workers.py
index 6425e99..a42b1a4 100644
--- a/python/sandcrawler/workers.py
+++ b/python/sandcrawler/workers.py
@@ -217,7 +217,7 @@ class KafkaSink(SandcrawlerWorker):
return self.counts
-class KafkaGrobidSink(KafkaSink):
+class KafkaCompressSink(KafkaSink):
"""
Variant of KafkaSink for large documents. Used for, eg, GROBID output.
"""