Repository navigation

Add Accelerated Kafka datasource. - #330

Merged

martindurant merged 28 commits into

python-streamz:masterfrom

chinmaychandak:kafka_cudf_ck

Apr 30, 2020

Merged

Add Accelerated Kafka datasource.#330
martindurant merged 28 commits into
python-streamz:masterfrom
chinmaychandak:kafka_cudf_ck

Commits on Mar 11, 2020
- Add engine=cudf in from_kafka_batched
  chinmaychandak
  committed
  73c0117
Commits on Mar 12, 2020
- Resolve merge conflicts
  chinmaychandak
  committed
  05a11c3
Commits on Mar 16, 2020
- Cleanup
  chinmaychandak
  committed
  11fa817
- Comments
  chinmaychandak
  committed
  becf49a
Commits on Mar 17, 2020
- Add an assign
  chinmaychandak
  committed
  398ac9d
- Cleanup
  chinmaychandak
  committed
  ba09ee5
- Cleanup
  chinmaychandak
  committed
  025707d
- Cleanup
  chinmaychandak
  committed
  5194e3d
- Cleanup
  chinmaychandak
  committed
  23d73fd
Commits on Mar 18, 2020
- Add doc string
  chinmaychandak
  committed
  6d58dc5
- Remove assign
  chinmaychandak
  committed
  c0b0a12
Commits on Mar 19, 2020
- Resolve merge conflicts
  chinmaychandak
  committed
  e5f3eab
- Formatting doc string
  chinmaychandak
  committed
  5900034
Commits on Mar 31, 2020
- Closing consumer properly to avoid memory leak
  chinmaychandak
  committed
  ab1a5a4
Commits on Apr 20, 2020
- Fix indent
  chinmaychandak
  committed
  e1ea43a
Commits on Apr 21, 2020
- Remove print statments and bare excepts
  chinmaychandak
  committed
  54750dc
- Formatting
  chinmaychandak
  committed
  680f4dc
- Add async def to Dask test with @gen_cluster
  chinmaychandak
  committed
  8e4bfa4
- Remove dask locks
  chinmaychandak
  committed
  d988482
- Fix new line
  chinmaychandak
  committed
  e32cc32
- Add pytest-tornasync to dependencies
  chinmaychandak
  committed
  071cdf2
- Cleanup dask workerspace
  chinmaychandak
  committed
  24cb24d
Commits on Apr 22, 2020
- Move to Python 3.7
  chinmaychandak
  committed
  7a402b9
- Remove incorrect package from yml file
  chinmaychandak
  committed
  b718882
Commits on Apr 24, 2020
- Revert async test changes
  chinmaychandak
  committed
  b10be90
- Remove ValueError
  chinmaychandak
  committed
  9aa67e2
Commits on Apr 28, 2020
- Badge for gpuCI, elaborate doc string, no-coverage for GPU branches
  chinmaychandak
  committed
  2311e14
Commits on Apr 29, 2020
- Add pragma no cover to .coveragerc
  chinmaychandak
  committed
  bd3814f

Commits

Commits on Mar 11, 2020

Commits on Mar 12, 2020

Commits on Mar 16, 2020

Commits on Mar 17, 2020

Commits on Mar 18, 2020

Commits on Mar 19, 2020

Commits on Mar 31, 2020

Commits on Apr 20, 2020

Commits on Apr 21, 2020

Commits on Apr 22, 2020

Commits on Apr 24, 2020

Commits on Apr 28, 2020

Commits on Apr 29, 2020