Temporarely remove pandas.

This commit is contained in:
aouinizied 2020-05-06 01:21:42 +02:00
parent 35300cea0e
commit 170c13ab3a

View file

@ -19,7 +19,6 @@ If not, see <http://www.gnu.org/licenses/>.
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