From commits-return-11096-archive-asf-public=cust-asf.ponee.io@hudi.apache.org Tue Feb 4 22:22:36 2020 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [207.244.88.153]) by mx-eu-01.ponee.io (Postfix) with SMTP id C7AD218064E for ; Tue, 4 Feb 2020 23:22:35 +0100 (CET) Received: (qmail 57292 invoked by uid 500); 4 Feb 2020 22:22:35 -0000 Mailing-List: contact commits-help@hudi.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@hudi.apache.org Delivered-To: mailing list commits@hudi.apache.org Received: (qmail 57273 invoked by uid 99); 4 Feb 2020 22:22:35 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 04 Feb 2020 22:22:35 +0000 From: GitBox To: commits@hudi.apache.org Subject: [GitHub] [incubator-hudi] bhasudha commented on a change in pull request #1306: [HUDI-598] Update quick start page Message-ID: <158085495483.6620.8675275132297671641.gitbox@gitbox.apache.org> References: In-Reply-To: Date: Tue, 04 Feb 2020 22:22:34 -0000 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit bhasudha commented on a change in pull request #1306: [HUDI-598] Update quick start page URL: https://github.com/apache/incubator-hudi/pull/1306#discussion_r374955592 ########## File path: docs/_docs/1_1_quick_start_guide.md ########## @@ -176,28 +176,28 @@ Delete records for the HoodieKeys passed in. ```scala // fetch total records count -spark.sql("select uuid, partitionPath from hudi_ro_table").count() +spark.sql("select uuid, partitionPath from hudi_trips_snapshot").count() // fetch two records to be deleted -val ds = spark.sql("select uuid, partitionPath from hudi_ro_table").limit(2) +val ds = spark.sql("select uuid, partitionPath from hudi_trips_snapshot").limit(2) // issue deletes val deletes = dataGen.generateDeletes(ds.collectAsList()) val df = spark.read.json(spark.sparkContext.parallelize(deletes, 2)); -df.write.format("org.apache.hudi"). -options(getQuickstartWriteConfigs). -option(OPERATION_OPT_KEY,"delete"). -option(PRECOMBINE_FIELD_OPT_KEY, "ts"). -option(RECORDKEY_FIELD_OPT_KEY, "uuid"). -option(PARTITIONPATH_FIELD_OPT_KEY, "partitionpath"). -option(TABLE_NAME, tableName). -mode(Append). -save(basePath); +df.write.format("hudi"). + options(getQuickstartWriteConfigs). + option(OPERATION_OPT_KEY,"delete"). + option(PRECOMBINE_FIELD_OPT_KEY, "ts"). + option(RECORDKEY_FIELD_OPT_KEY, "uuid"). + option(PARTITIONPATH_FIELD_OPT_KEY, "partitionpath"). + option(TABLE_NAME, tableName). + mode(Append). + save(basePath) // run the same read query as above. val roAfterDeleteViewDF = spark. - read. - format("org.apache.hudi"). - load(basePath + "/*/*/*/*") + read. + format("hudi"). + load(basePath + "/*/*/*/*") roAfterDeleteViewDF.registerTempTable("hudi_ro_table") // fetch should return (total - 2) records spark.sql("select uuid, partitionPath from hudi_ro_table").count() Review comment: hudi_ro_table -> hudi_trips_snapshot here as well. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: users@infra.apache.org With regards, Apache Git Services