Hello. I am trying to write code for cross language transform for ElasticsearchIO but having trouble with it. I would appreciate it if I could get help.
As describe in doc and also referencing KafkaIO , https://beam.apache.org/documentation/programming-guide/#1311-creating-cross-language-java-transforms I have annotated the code with @AutoService but the 'elasticsearch_write' does not appear when starting Expansion Service. https://github.com/yuwtennis/beam/blob/feat/elasticsearch-io-cross-lang/sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java#L1991 Below is the snippet of command line operation. https://gist.github.com/yuwtennis/3c55ca45b31f9a302daf7b827a842ef6 I have built jar files with the below command in advance . ./gradlew :sdks:java [jar] Would there be any other instructions I should be referencing ? Best Regards, Yu Watanabe -- Yu Watanabe linkedin: www.linkedin.com/in/yuwatanabe1/ twitter: twitter.com/yuwtennis
