diff --git a/nfstream/streamer.py b/nfstream/streamer.py index a148aa0..d0cb783 100644 --- a/nfstream/streamer.py +++ b/nfstream/streamer.py @@ -19,7 +19,6 @@ If not, see . from .cache import NFCache from .observer import NFObserver from threading import Thread -import pandas as pd import time as tm import zmq import sys @@ -79,12 +78,3 @@ class NFStreamer(object): self.cache.stopped = True except RuntimeError: return None - - def to_pandas(self): - """ streamer to pandas function """ - data = [] - for flow in self: - data.append(flow.to_namedtuple()) - df = pd.DataFrame(data=data) - del data - return df