Skip to content

Commit

Permalink
.
Browse files Browse the repository at this point in the history
  • Loading branch information
yirutang committed Apr 1, 2021
1 parent 19ed916 commit 1fba6e5
Show file tree
Hide file tree
Showing 11 changed files with 22 additions and 34 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@
*/
package com.google.cloud.bigquery.storage.v1alpha2;

import com.google.cloud.GcpLaunchStage;
import com.google.common.base.Preconditions;
import com.google.common.collect.ImmutableList;
import com.google.common.collect.ImmutableMap;
Expand All @@ -34,9 +33,9 @@
* when constructing the protobuf descriptor. The mapping between field types and field modes are
* shown in the ImmutableMaps below.
*
* @deprecated
* @deprecated Use {@link com.google.cloud.bigquery.storage.v1beta2.BQTableSchemaToProtoDescriptor}
*/
@GcpLaunchStage.Deprecated
@Deprecated
public class BQTableSchemaToProtoDescriptor {
private static ImmutableMap<Table.TableFieldSchema.Mode, FieldDescriptorProto.Label>
BQTableSchemaModeMap =
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,6 @@
import com.google.api.core.ApiFutures;
import com.google.api.gax.grpc.GrpcStatusCode;
import com.google.api.gax.rpc.InvalidArgumentException;
import com.google.cloud.GcpLaunchStage;
import com.google.cloud.bigquery.storage.v1alpha2.ProtoBufProto.ProtoRows;
import com.google.cloud.bigquery.storage.v1alpha2.Storage.AppendRowsRequest;
import com.google.common.annotations.VisibleForTesting;
Expand Down Expand Up @@ -50,9 +49,9 @@
* <p>{@link DirectWriter} will use the credentials set on the channel, which uses application
* default credentials through {@link GoogleCredentials#getApplicationDefault} by default.
*
* @deprecated
* @deprecated no longer supported
*/
@GcpLaunchStage.Deprecated
@Deprecated
public class DirectWriter {
private static final Logger LOG = Logger.getLogger(DirectWriter.class.getName());
private static WriterCache cache = null;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,6 @@
import com.google.api.gax.core.ExecutorProvider;
import com.google.api.gax.retrying.RetrySettings;
import com.google.api.gax.rpc.TransportChannelProvider;
import com.google.cloud.GcpLaunchStage;
import com.google.cloud.bigquery.storage.v1alpha2.ProtoBufProto.ProtoRows;
import com.google.cloud.bigquery.storage.v1alpha2.Storage.AppendRowsRequest;
import com.google.cloud.bigquery.storage.v1alpha2.Storage.AppendRowsResponse;
Expand All @@ -46,9 +45,9 @@
* table schema is updated, users will be able to ingest data on the new schema after some time (in
* order of minutes).
*
* @deprecated
* @deprecated Use {@link com.google.cloud.bigquery.storage.v1alpha2.JsonStreamWriter}
*/
@GcpLaunchStage.Deprecated
@Deprecated
public class JsonStreamWriter implements AutoCloseable {
private static String streamPatternString =
"projects/[^/]+/datasets/[^/]+/tables/[^/]+/streams/[^/]+";
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@
*/
package com.google.cloud.bigquery.storage.v1alpha2;

import com.google.cloud.GcpLaunchStage;
import com.google.common.base.Preconditions;
import com.google.common.collect.ImmutableMap;
import com.google.protobuf.Descriptors.Descriptor;
Expand All @@ -31,9 +30,9 @@
* Converts Json data to protocol buffer messages given the protocol buffer descriptor. The protobuf
* descriptor must have all fields lowercased.
*
* @deprecated
* @deprecated Use {@link com.google.cloud.bigquery.storage.v1beta2.JsonToProtoMessage}
*/
@GcpLaunchStage.Deprecated
@Deprecated
public class JsonToProtoMessage {
private static ImmutableMap<FieldDescriptor.Type, String> FieldTypeToDebugMessage =
new ImmutableMap.Builder<FieldDescriptor.Type, String>()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@
*/
package com.google.cloud.bigquery.storage.v1alpha2;

import com.google.cloud.GcpLaunchStage;
import com.google.common.annotations.VisibleForTesting;
import com.google.common.base.Preconditions;
import com.google.common.cache.Cache;
Expand All @@ -32,9 +31,9 @@
* minutes if not used. Code sample: JsonWriterCache cache = JsonWriterCache.getInstance();
* JsonStreamWriter writer = cache.getWriter(); // Use... cache.returnWriter(writer);
*
* @deprecated
* @deprecated No longer supported
*/
@GcpLaunchStage.Deprecated
@Deprecated
public class JsonWriterCache {
private static final Logger LOG = Logger.getLogger(JsonWriterCache.class.getName());

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,16 +15,14 @@
*/
package com.google.cloud.bigquery.storage.v1alpha2;

import com.google.cloud.GcpLaunchStage;

/**
* A abstract class that implements the Runnable interface and provides access to the current
* StreamWriter and updatedSchema. This runnable will only be called when a updated schema has been
* passed back through the AppendRowsResponse. Users should only implement the run() function.
*
* @deprecated
* @deprecated Use {@link com.google.cloud.bigquery.storage.v1beta2.OnSchemaUpdateRunnable}
*/
@GcpLaunchStage.Deprecated
@Deprecated
public abstract class OnSchemaUpdateRunnable implements Runnable {
private StreamWriter streamWriter;
private Table.TableSchema updatedSchema;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@

import com.google.api.gax.grpc.GrpcStatusCode;
import com.google.api.gax.rpc.InvalidArgumentException;
import com.google.cloud.GcpLaunchStage;
import com.google.cloud.bigquery.storage.v1alpha2.ProtoBufProto.ProtoSchema;
import com.google.protobuf.DescriptorProtos.DescriptorProto;
import com.google.protobuf.DescriptorProtos.EnumDescriptorProto;
Expand All @@ -31,8 +30,8 @@
// A Converter class that turns a native protobuf::DescriptorProto to a self contained
// protobuf::DescriptorProto
// that can be reconstructed by the backend.
// @deprecated
@GcpLaunchStage.Deprecated
// @deprecated Use {@link com.google.cloud.bigquery.storage.v1beta2.ProtoSchemaConverter}
@Deprecated
public class ProtoSchemaConverter {
private static String getNameFromFullName(String fullName) {
return fullName.replace('.', '_');
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@
*/
package com.google.cloud.bigquery.storage.v1alpha2;

import com.google.cloud.GcpLaunchStage;
import com.google.cloud.bigquery.BigQuery;
import com.google.cloud.bigquery.Field;
import com.google.cloud.bigquery.LegacySQLTypeName;
Expand Down Expand Up @@ -43,9 +42,9 @@
* <p>The implementation as of now is not complete, which measn, if this check passed, there is
* still a possbility of writing will fail.
*
* @deprecated
* @deprecated Use {@link com.google.cloud.bigquery.storage.v1beta2.SchemaCompatibility}
*/
@GcpLaunchStage.Deprecated
@Deprecated
public class SchemaCompatibility {
private BigQuery bigquery;
private static SchemaCompatibility compat;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,6 @@
import com.google.api.gax.rpc.StreamController;
import com.google.api.gax.rpc.TransportChannelProvider;
import com.google.auth.oauth2.GoogleCredentials;
import com.google.cloud.GcpLaunchStage;
import com.google.cloud.bigquery.storage.v1alpha2.Storage.AppendRowsRequest;
import com.google.cloud.bigquery.storage.v1alpha2.Storage.AppendRowsResponse;
import com.google.common.base.Preconditions;
Expand Down Expand Up @@ -80,9 +79,9 @@
* <p>{@link StreamWriter} will use the credentials set on the channel, which uses application
* default credentials through {@link GoogleCredentials#getApplicationDefault} by default.
*
* @deprecated
* @deprecated Use {@link com.google.cloud.bigquery.storage.v1alpha2.JsonStreamWriterV2}
*/
@GcpLaunchStage.Deprecated
@Deprecated
public class StreamWriter implements AutoCloseable {
private static final Logger LOG = Logger.getLogger(StreamWriter.class.getName());

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,6 @@
import com.google.api.core.InternalApi;
import com.google.api.gax.batching.FlowControlSettings;
import com.google.api.gax.batching.FlowController;
import com.google.cloud.GcpLaunchStage;
import java.util.LinkedList;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.locks.Lock;
Expand All @@ -30,9 +29,9 @@
* A barrier kind of object that helps keep track of pending actions and synchronously wait until
* all have completed.
*
* @deprecated
* @deprecated No longer supported
*/
@GcpLaunchStage.Deprecated
@Deprecated
class Waiter {
private static final Logger LOG = Logger.getLogger(Waiter.class.getName());

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@
*/
package com.google.cloud.bigquery.storage.v1alpha2;

import com.google.cloud.GcpLaunchStage;
import com.google.common.annotations.VisibleForTesting;
import com.google.common.base.Preconditions;
import com.google.common.cache.Cache;
Expand All @@ -34,9 +33,9 @@
* minutes if not used. Code sample: WriterCache cache = WriterCache.getInstance(); StreamWriter
* writer = cache.getWriter(); // Use... cache.returnWriter(writer);
*
* @deprecated
* @deprecated No longer supported
*/
@GcpLaunchStage.Deprecated
@Deprecated
public class WriterCache {
private static final Logger LOG = Logger.getLogger(WriterCache.class.getName());

Expand Down

0 comments on commit 1fba6e5

Please sign in to comment.