Member since
01-30-2024
4
Posts
1
Kudos Received
0
Solutions
02-28-2024
06:29 AM
I want to keep a collection of key values in the flink which must be distributed, so that it can be accessed later for lookup from anywhere, which is the right approach to do in Flink and what are the alternatives ?
... View more
Labels:
- Labels:
-
Apache Flink
02-15-2024
05:15 AM
1 Kudo
Hi Team, I am trying to access a global variable set in my main class under the StreamExecutionEnvironment. I am trying to access the global variable in a different class which is in different package where I am not using RichFunction ?. If I rephrase- can I place a variable in main class which can be accessed any where with in the application (like the static variable in JAVA standalone app) where I am not using directly the execution environment or rich function's other than in the main class?
... View more
Labels:
- Labels:
-
Apache Flink
01-31-2024
05:29 AM
with the above given options, it is only taking the timerange start and end , not considering the rowkey passed along with it.
... View more
01-30-2024
09:22 PM
I am trying to pull the records from the Hbase based on the row key in pyspark using the following details but the records which is returning showing all the records (i,e without filter), can you please help me to resolving the issue
... View more
Labels:
- Labels:
-
Apache HBase
-
Apache Spark