Job job = new Job(); JobConfiguration config = new JobConfiguration(); JobConfigurationQuery queryConfig = new JobConfigurationQuery(); config.setQuery(queryConfig); job.setConfiguration(config); queryConfig.setQuery(querySql); queryConfig.setPriority("BATCH"); com.google.api.services.bigquery.Bigquery.Jobs.Insert insert = bigquery.jobs().insert(projectId, job);
try { // Devolver las credenciales desde el datastore de App Engine. DatastoreService datastore = DatastoreServiceFactory.getDatastoreService(); Key credsKey = KeyFactory.createKey("Credentials", "Credentials"); credentials = datastore.get(credsKey); } catch (EntityNotFoundException ex) { // Si no se pueden obtener las credenciales enviamos una exception al cliente javascript. response.setContentType("text/html"); response.getWriter().println("exception: " + ex.getMessage()); }
// Establecer el acceso OAuth 2.0 GoogleAccessProtectedResource requestInitializer = new GoogleAccessProtectedResource(tokens.accessToken,httpTransport, jsonFactory, clientId, clientSecret, tokens.refreshToken);
// Finalmente completar los datos de predición llamada a la API and trabajar los resultados en la Javascript AJAX cliente Prediction prediction = new Prediction(httpTransport, requestInitializer, jsonFactory); Input input = new Input(); InputInput inputInput = new InputInput(); inputInput.setCsvInstance(params); input.setInput(inputInput); Output output = prediction.trainedmodels().predict(modelId, input).execute();
