microsoft streaming real-time scala kafka spark apache-spark stream connector azure bigdata apache spark-streaming eventhubs ingestion continuous event-hubs databricks structured-streaming

java spark ingestion udf dataframe data-ingestion

workflow hadoop ingestion oozie sqoop sqoop2 workflow-automation workflow-scheduler hadoop-ecosystem hadoop-framework ibis cigna

mysql bot money reddit ingestion

opencv encoding workflow cloud video computer-vision ffmpeg download encoder workflow-engine overlay media cut ingestion delivery-api workflows concatenate delivery

streaming framework kafka spark apache-spark pipeline ingestion streaming-etl spark-structured-streaming

data-science data-mining hadoop bigdata ingestion realtime-messaging vertica streaming-data etl-pipeline

redis kafka stream queue rabbitmq asynchronous sqs reverse-proxy message-queue ingestion high-availability fan-out back-pressure entrypoint

java mongodb pipeline activemq ingestion dats

java ingestion zmon data-service

go golang elasticsearch concurrency ingestion bulk backpressure

docker interoperability oceanography ingestion insitu tagbase-server etuff

scala hadoop ingestion pipewrench

java spark apache-spark java8 ingestion manning sparkwithjava

microservice linked-data ingestion replicate daf km4city

elasticsearch kibana ingestion visualizations

nodejs json node scala csv kafka broadway actors avro etl narrative flow-control ingestion etl-framework avro-format

data-science data-visualization data-analytics ingestion data-processing data-pipeline

data csv dynamic uploader ingestion dataservice

mongodb ingestion gedcom geneology

python government data united-states ingestion executive-branch presidents executive-orders

unix hive hadoop etl ingestion sqoop

bigquery airflow google composer cloud gcp operator dataflow ingestion periodic dag change-data inceremental merge-query bigqueryoperator dataflowtemplateoperator

api kafka rest ingestion

hadoop ingestion bigdatateam

api linguistics import ingestion linguistic-analysis cherokee-language

api aws s3 gateway kinesis ingestion

nodejs tsv json node scala csv etl scalajs ingestion etl-framework scalajs-io

data assets ingestion leak dlp prevention magen

ansible automation media ingestion mapreduce batch-processing