Question

Scala 2.11 compilation for the Apache Bahir Library

score 103 · Answer 1 · 2020-10-08 02:16:52

103

Views

Scala 2.11 compilation for the Apache Bahir Library

Published on 08 October 2020 at 02:16

score 174 · Answer 2 · 2020-12-09 14:59:59

174

Views

Unable to start Spark application with Bahir

Published on 09 December 2020 at 14:59

score 321 · Answer 3 · 2020-12-10 06:40:18

321

Views

MqttException while connecting to ActiveMq via SparkStructedStreaming

Published on 10 December 2020 at 06:40

score 418 · Answer 4 · 2020-12-13 21:41:21

418

Views

How to send data from spark-structured-streaming to a topic of ActiveMQ

Published on 13 December 2020 at 21:41

score 373 · Answer 5 · 2018-09-23 16:12:39

373

Views

Apache Spark 2.3.1 - twitter is not a member of package org.apache.spark.streaming

Published on 23 September 2018 at 16:12

score 535 · Answer 6 · 2018-07-26 10:55:46

535

Views

DataFrame returned by getBatch from MQTTTextStreamSource did not have isStreaming=true

Published on 26 July 2018 at 10:55

score 706 · Answer 7 · 2021-10-13 12:44:21

706

Views

java.lang.ClassNotFoundException: Failed to find data source: org.apache.bahir.sql.streaming.mqtt.MQTTStreamSinkProvider. Please find packages

Published on 13 October 2021 at 12:44

score 424 · Answer 8 · 2021-08-15 18:03:22

424

Views

What is the difference between two Flink Redis sink dependencies with groupId `org.apache.bahir` and `org.apache.flink`?

Published on 15 August 2021 at 18:03

score 244 · Answer 9 · 2021-02-24 19:31:33

244

Views

Large data with Spark and CouchDB

Published on 24 February 2021 at 19:31

score 490 · Answer 10 · 2018-12-05 14:41:18

Why does query throw ClassCastException "SerializedOffset cannot be cast to org.apache.spark.sql.execution.streaming.LongOffset" with MQTT Source?

score 106 · Answer 11 · 2017-01-28 19:18:09

106

Views

Apache Bahir, send stuff to ActorReceiver

Published on 28 January 2017 at 19:18

score 135 · Answer 12 · 2021-07-12 15:43:03

135

Views

KuduSink<MyModel> fails to start

Published on 12 July 2021 at 15:43

score 283 · Answer 13 · 2017-02-03 06:37:03

283

Views

Schema issue with ApacheBahir Stuctured Streaming connector on ApacheSpark streaming

Published on 03 February 2017 at 06:37

score 185 · Answer 14 · 2017-02-06 15:48:10

185

Views

Schema lost with ApacheBahir Stuctured Streaming connector on ApacheSpark streaming

Published on 06 February 2017 at 15:48

score 1k · Answer 15 · 2019-03-21 17:15:46

1k

Views

pyspark MQTT structured streaming with apache bahir

Published on 21 March 2019 at 17:15

score 282 · Answer 16 · 2019-02-28 15:37:55

282

Views

Flink job with AMQSource doesn't generate output

Published on 28 February 2019 at 15:37

score 124 · Answer 17 · 2019-03-05 10:14:39

124

Views

How to use createpairedStream in MQTTUtils?

Published on 05 March 2019 at 10:14

score 126 · Answer 18 · 2019-03-13 04:59:26

126

Views

MQTTUtils.createPairedStream() is not a member of org.apache.bahir

Published on 13 March 2019 at 04:59

score 1.4k · Answer 19 · 2017-10-16 10:58:27

1.4k

Views

On adding a jar using mvn install: install-file: On project standalone-pom: The artifact information is incomplete or not valid

Published on 16 October 2017 at 10:58

score 361 · Answer 20 · 2017-11-10 05:24:31

361

Views

Causes of "java.lang.NoSuchMethodError: org.eclipse.paho.client.mqttv3.MqttConnectOptions.setAutomaticReconnect(Z)V"

Published on 10 November 2017 at 05:24

List Question

Scala 2.11 compilation for the Apache Bahir Library

Unable to start Spark application with Bahir

MqttException while connecting to ActiveMq via SparkStructedStreaming

How to send data from spark-structured-streaming to a topic of ActiveMQ

Apache Spark 2.3.1 - twitter is not a member of package org.apache.spark.streaming

DataFrame returned by getBatch from MQTTTextStreamSource did not have isStreaming=true

java.lang.ClassNotFoundException: Failed to find data source: org.apache.bahir.sql.streaming.mqtt.MQTTStreamSinkProvider. Please find packages

What is the difference between two Flink Redis sink dependencies with groupId `org.apache.bahir` and `org.apache.flink`?

Large data with Spark and CouchDB

Why does query throw ClassCastException "SerializedOffset cannot be cast to org.apache.spark.sql.execution.streaming.LongOffset" with MQTT Source?

Apache Bahir, send stuff to ActorReceiver

KuduSink<MyModel> fails to start

Schema issue with ApacheBahir Stuctured Streaming connector on ApacheSpark streaming

Schema lost with ApacheBahir Stuctured Streaming connector on ApacheSpark streaming

pyspark MQTT structured streaming with apache bahir

Flink job with AMQSource doesn't generate output

How to use createpairedStream in MQTTUtils?

MQTTUtils.createPairedStream() is not a member of org.apache.bahir

On adding a jar using mvn install: install-file: On project standalone-pom: The artifact information is incomplete or not valid

Causes of "java.lang.NoSuchMethodError: org.eclipse.paho.client.mqttv3.MqttConnectOptions.setAutomaticReconnect(Z)V"

Trending Questions

Popular # Hahtags

Popular Questions