public static void main(String[] args) throws IOException {

// TODO(developer): Replace these variables before running the sample.

String project = "PROJECT";

String displayName = "DISPLAY_NAME";

String dataset = "DATASET";

String instructionUri = "INSTRUCTION_URI";

String inputsSchemaUri = "INPUTS_SCHEMA_URI";

String annotationSpec = "ANNOTATION_SPEC";

createDataLabelingJobActiveLearningSample(

project, displayName, dataset, instructionUri, inputsSchemaUri, annotationSpec);

}

static void createDataLabelingJobActiveLearningSample(

String project,

String displayName,

String dataset,

String instructionUri,

String inputsSchemaUri,

String annotationSpec)

throws IOException {

JobServiceSettings settings =

JobServiceSettings.newBuilder()

.setEndpoint("us-central1-aiplatform.googleapis.com:443")

.build();

String location = "us-central1";

// 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 (JobServiceClient client = JobServiceClient.create(settings)) {

JsonArray jsonAnnotationSpecs = new JsonArray();

jsonAnnotationSpecs.add(annotationSpec);

JsonObject jsonInputs = new JsonObject();

jsonInputs.add("annotation_specs", jsonAnnotationSpecs);

Value.Builder inputsBuilder = Value.newBuilder();

JsonFormat.parser().merge(jsonInputs.toString(), inputsBuilder);

Value inputs = inputsBuilder.build();

ActiveLearningConfig activeLearningConfig =

ActiveLearningConfig.newBuilder().setMaxDataItemCount(1).build();

String datasetName = DatasetName.of(project, location, dataset).toString();

DataLabelingJob dataLabelingJob =

DataLabelingJob.newBuilder()

.setDisplayName(displayName)

.addDatasets(datasetName)

.setLabelerCount(1)

.setInstructionUri(instructionUri)

.setInputsSchemaUri(inputsSchemaUri)

.setInputs(inputs)

.putAnnotationLabels(

"aiplatform.googleapis.com/annotation_set_name",

"data_labeling_job_active_learning")

.setActiveLearningConfig(activeLearningConfig)

.build();

LocationName parent = LocationName.of(project, location);

DataLabelingJob response = client.createDataLabelingJob(parent, dataLabelingJob);

System.out.format("response: %s\n", response);

System.out.format("Name: %s\n", response.getName());

}

}