aiplatform/src/main/java/aiplatform/ImportDataTextClassificationSingleLabelSample.java [49:88]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - static void importDataTextClassificationSingleLabelSample( String project, String datasetId, String gcsSourceUri) throws IOException, InterruptedException, ExecutionException, TimeoutException { DatasetServiceSettings datasetServiceSettings = DatasetServiceSettings.newBuilder() .setEndpoint("us-central1-aiplatform.googleapis.com:443") .build(); // Initialize client that will be used to send requests. This client only needs to be created // once, and can be reused for multiple requests. After completing all of your requests, call // the "close" method on the client to safely clean up any remaining background resources. try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create(datasetServiceSettings)) { String location = "us-central1"; String importSchemaUri = "gs://google-cloud-aiplatform/schema/dataset/ioformat/" + "text_classification_single_label_io_format_1.0.0.yaml"; GcsSource.Builder gcsSource = GcsSource.newBuilder(); gcsSource.addUris(gcsSourceUri); DatasetName datasetName = DatasetName.of(project, location, datasetId); List importDataConfigList = Collections.singletonList( ImportDataConfig.newBuilder() .setGcsSource(gcsSource) .setImportSchemaUri(importSchemaUri) .build()); OperationFuture importDataResponseFuture = datasetServiceClient.importDataAsync(datasetName, importDataConfigList); System.out.format( "Operation name: %s\n", importDataResponseFuture.getInitialFuture().get().getName()); System.out.println("Waiting for operation to finish..."); ImportDataResponse importDataResponse = importDataResponseFuture.get(300, TimeUnit.SECONDS); System.out.format( "Import Data Text Classification Response: %s\n", importDataResponse.toString()); } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - aiplatform/src/main/java/aiplatform/ImportDataImageObjectDetectionSample.java [48:86]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - static void importDataImageObjectDetectionSample( String project, String datasetId, String gcsSourceUri) throws IOException, InterruptedException, ExecutionException, TimeoutException { DatasetServiceSettings datasetServiceSettings = DatasetServiceSettings.newBuilder() .setEndpoint("us-central1-aiplatform.googleapis.com:443") .build(); // Initialize client that will be used to send requests. This client only needs to be created // once, and can be reused for multiple requests. After completing all of your requests, call // the "close" method on the client to safely clean up any remaining background resources. try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create(datasetServiceSettings)) { String location = "us-central1"; String importSchemaUri = "gs://google-cloud-aiplatform/schema/dataset/ioformat/" + "image_bounding_box_io_format_1.0.0.yaml"; GcsSource.Builder gcsSource = GcsSource.newBuilder(); gcsSource.addUris(gcsSourceUri); DatasetName datasetName = DatasetName.of(project, location, datasetId); List importDataConfigList = Collections.singletonList( ImportDataConfig.newBuilder() .setGcsSource(gcsSource) .setImportSchemaUri(importSchemaUri) .build()); OperationFuture importDataResponseFuture = datasetServiceClient.importDataAsync(datasetName, importDataConfigList); System.out.format( "Operation name: %s\n", importDataResponseFuture.getInitialFuture().get().getName()); System.out.println("Waiting for operation to finish..."); ImportDataResponse importDataResponse = importDataResponseFuture.get(300, TimeUnit.SECONDS); System.out.format( "Import Data Image Object Detection Response: %s\n", importDataResponse.toString()); } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - aiplatform/src/main/java/aiplatform/ImportDataImageClassificationSample.java [48:87]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - static void importDataImageClassificationSample( String project, String datasetId, String gcsSourceUri) throws IOException, InterruptedException, ExecutionException, TimeoutException { DatasetServiceSettings datasetServiceSettings = DatasetServiceSettings.newBuilder() .setEndpoint("us-central1-aiplatform.googleapis.com:443") .build(); // Initialize client that will be used to send requests. This client only needs to be created // once, and can be reused for multiple requests. After completing all of your requests, call // the "close" method on the client to safely clean up any remaining background resources. try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create(datasetServiceSettings)) { String location = "us-central1"; String importSchemaUri = "gs://google-cloud-aiplatform/schema/dataset/ioformat/" + "image_classification_single_label_io_format_1.0.0.yaml"; GcsSource.Builder gcsSource = GcsSource.newBuilder(); gcsSource.addUris(gcsSourceUri); DatasetName datasetName = DatasetName.of(project, location, datasetId); List importDataConfigList = Collections.singletonList( ImportDataConfig.newBuilder() .setGcsSource(gcsSource) .setImportSchemaUri(importSchemaUri) .build()); OperationFuture importDataResponseFuture = datasetServiceClient.importDataAsync(datasetName, importDataConfigList); System.out.format( "Operation name: %s\n", importDataResponseFuture.getInitialFuture().get().getName()); System.out.println("Waiting for operation to finish..."); ImportDataResponse importDataResponse = importDataResponseFuture.get(300, TimeUnit.SECONDS); System.out.format( "Import Data Image Classification Response: %s\n", importDataResponse.toString()); } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - aiplatform/src/main/java/aiplatform/ImportDataTextEntityExtractionSample.java [48:87]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - static void importDataTextEntityExtractionSample( String project, String datasetId, String gcsSourceUri) throws IOException, InterruptedException, ExecutionException, TimeoutException { DatasetServiceSettings datasetServiceSettings = DatasetServiceSettings.newBuilder() .setEndpoint("us-central1-aiplatform.googleapis.com:443") .build(); // Initialize client that will be used to send requests. This client only needs to be created // once, and can be reused for multiple requests. After completing all of your requests, call // the "close" method on the client to safely clean up any remaining background resources. try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create(datasetServiceSettings)) { String location = "us-central1"; String importSchemaUri = "gs://google-cloud-aiplatform/schema/dataset/ioformat/" + "text_extraction_io_format_1.0.0.yaml"; GcsSource.Builder gcsSource = GcsSource.newBuilder(); gcsSource.addUris(gcsSourceUri); DatasetName datasetName = DatasetName.of(project, location, datasetId); List importDataConfigList = Collections.singletonList( ImportDataConfig.newBuilder() .setGcsSource(gcsSource) .setImportSchemaUri(importSchemaUri) .build()); OperationFuture importDataResponseFuture = datasetServiceClient.importDataAsync(datasetName, importDataConfigList); System.out.format( "Operation name: %s\n", importDataResponseFuture.getInitialFuture().get().getName()); System.out.println("Waiting for operation to finish..."); ImportDataResponse importDataResponse = importDataResponseFuture.get(300, TimeUnit.SECONDS); System.out.format( "Import Data Text Entity Extraction Response: %s\n", importDataResponse.toString()); } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - aiplatform/src/main/java/aiplatform/ImportDataTextSentimentAnalysisSample.java [49:88]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - static void importDataTextSentimentAnalysisSample( String project, String datasetId, String gcsSourceUri) throws IOException, InterruptedException, ExecutionException, TimeoutException { DatasetServiceSettings datasetServiceSettings = DatasetServiceSettings.newBuilder() .setEndpoint("us-central1-aiplatform.googleapis.com:443") .build(); // Initialize client that will be used to send requests. This client only needs to be created // once, and can be reused for multiple requests. After completing all of your requests, call // the "close" method on the client to safely clean up any remaining background resources. try (DatasetServiceClient datasetServiceClient = DatasetServiceClient.create(datasetServiceSettings)) { String location = "us-central1"; String importSchemaUri = "gs://google-cloud-aiplatform/schema/dataset/ioformat/" + "text_sentiment_io_format_1.0.0.yaml"; GcsSource.Builder gcsSource = GcsSource.newBuilder(); gcsSource.addUris(gcsSourceUri); DatasetName datasetName = DatasetName.of(project, location, datasetId); List importDataConfigList = Collections.singletonList( ImportDataConfig.newBuilder() .setGcsSource(gcsSource) .setImportSchemaUri(importSchemaUri) .build()); OperationFuture importDataResponseFuture = datasetServiceClient.importDataAsync(datasetName, importDataConfigList); System.out.format( "Operation name: %s\n", importDataResponseFuture.getInitialFuture().get().getName()); System.out.println("Waiting for operation to finish..."); ImportDataResponse importDataResponse = importDataResponseFuture.get(300, TimeUnit.SECONDS); System.out.format( "Import Data Text Sentiment Analysis Response: %s\n", importDataResponse.toString()); } } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -