[jira] [Created] (BEAM-1151) BigQueryIO.Write has no way of handling failures
Reuven Lax created BEAM-1151: Summary: BigQueryIO.Write has no way of handling failures Key: BEAM-1151 URL: https://issues.apache.org/jira/browse/BEAM-1151 Project: Beam Issue Type: Bug Components: sdk-java-core Affects Versions: 0.4.0-incubating Reporter: Reuven Lax Assignee: Reuven Lax Fix For: 0.3.0-incubating BigQueryIO.Write in streaming mode uses BigQuery's streaming insert API. Inserts can fail for a variety of reasons, and the current connector provides no way of managing those failures. This PR allows better failure handling. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (BEAM-1022) TableNamespace should not use Java object equality when comparing windows
Reuven Lax created BEAM-1022: Summary: TableNamespace should not use Java object equality when comparing windows Key: BEAM-1022 URL: https://issues.apache.org/jira/browse/BEAM-1022 Project: Beam Issue Type: Bug Components: beam-model Affects Versions: 0.3.0-incubating Reporter: Reuven Lax Assignee: Thomas Groh -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (BEAM-974) Adds attributes support to PubsubIO
Reuven Lax created BEAM-974: --- Summary: Adds attributes support to PubsubIO Key: BEAM-974 URL: https://issues.apache.org/jira/browse/BEAM-974 Project: Beam Issue Type: Improvement Components: sdk-java-core Affects Versions: 0.3.0-incubating Reporter: Reuven Lax Assignee: Davor Bonaci Fix For: 0.4.0-incubating Adds support for Pubsub attributes by introducing a new PubsubMessage class that allows manipulation of payload and attributes. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
