# Path: peachbox/model/batch_view.py
# class BatchView(RealTimeView):
#     pass


import unittest
import peachbox.connector.sink
from peachbox.model import BatchView

class BatchModel(BatchView):
    mart = 'test_mart'
    key  = 'f1'

    schema = [{'field':'f1', 'type':'IntegerType'},
              {'field':'f2', 'type':'StringType'}]

class TestBatchView(unittest.TestCase):
    def test_absorb(self):
        input = peachbox.Spark.Instance().context().parallelize([BatchModel.row(f1=1, f2='value')])

# Path: peachbox/model/batch_view.py
# class BatchView(RealTimeView):
#     pass


# Path: peachbox/connector/sink/tests/test_batch_view.py
import unittest
import peachbox.connector.sink
from peachbox.model import BatchView


class BatchModel(BatchView):
    mart = 'test_mart'
    key  = 'f1'

    schema = [{'field':'f1', 'type':'IntegerType'},
              {'field':'f2', 'type':'StringType'}]

class TestBatchView(unittest.TestCase):
    def test_absorb(self):
        input = peachbox.Spark.Instance().context().parallelize([BatchModel.row(f1=1, f2='value')])

        b = peachbox.connector.sink.BatchView()