forked from apache/beam
-
Notifications
You must be signed in to change notification settings - Fork 0
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
transform for Cloud AI LanguageServiceClient #6
Labels
Milestone
Comments
|
DariuszAniszewski
pushed a commit
that referenced
this issue
Feb 26, 2020
beam merge 19/02/2020 2:29 AM
Jakub-Sadowski
pushed a commit
that referenced
this issue
Jan 17, 2021
… to Google Pub/Sub (apache#13112) * add initial template and dependencies * Added flex template creation with metadata support and instructions * added new gradle modules for templates * moved metadata to template location, reverted examples build.gradle * Moved KafkaToPubsub to template, implemented options in separate package * Added package-info.java to new packages * Reverted build.gradle to master branch state * fixed JAVADOC and metadata * Added the Read Me section with a step-by-step guide * Update README.md * Readme fixes regarding comments * Update README.md * Update README.md * Fixed typos in README.md * refactored README.md added case to run template locally * Update README.md * fix build script for dataflow in README.md * Added unit test and fixed metadata file * Added Licenses and style fixes * Added support for retrieving Kafka credentials from HashiCorp Vault secret storage with url and token * Updated README.md and metadata with parameters for Vault access; refactored Kafka configuration * Style fix * Added description for Vault parameters in metadata * FIX trailing whitespaces in README.md * FIX. Blank line contains whitespace README.md * Update README.md * Refactored to examples folder * Added conversion from JSON into PubsubMessage and extracted all transformations from the pipeline class into the separate class * Whitespacelint fix * Updated README.md and output formats * Update README.md * Update README.md * Added support for SSL and removed outputFormat option * Added avro usage example * Added ssl to AVRO reader * FIX whitespaces. * added readme/docs regarding of Avro * README.md and javadoc fixes * Added Vault's response JSON schema description * Style fix * Refactoring. * Fixed ssl parameters * Fixed style * optimize build.gradle * Resolve conversations * Updated regarding comments and added unit tests * README.md update * made Avro class more abstract * fix style * fixed review conversation items * fix getting ssl credentials from Vault * FIX add empty && null map validation to sslConfig * FIX. remove vault ssl certs parameters * metadata fix * Local paths fix for SSL from GCS * add new log message to avoid wrong local files usage * fix style * Moved kafka-to-pubsub to examples/ directory and updated README.md (#6) * Stylefix * Removed unused file * add tbd section for e-2-e tests * fix styles * specifying kafka-clients version * fix readme * template -> exmples * Update examples/kafka-to-pubsub/README.md Co-authored-by: Brian Hulette <[email protected]> * Fixed outdated import * Moved template to examples/complete * Updated paths in readme file * Updated README.md and javadoc regarding comments * README.md stylefix * Added link to KafkaToPubsub example into complete/README.md * Stylefix Co-authored-by: Artur Khanin <[email protected]> Co-authored-by: Artur Khanin <[email protected]> Co-authored-by: AKosolapov <[email protected]> Co-authored-by: ramazan-yapparov <[email protected]> Co-authored-by: Ramazan Yapparov <[email protected]> Co-authored-by: Brian Hulette <[email protected]>
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
No description provided.
The text was updated successfully, but these errors were encountered: