From 5d4368bbca936631e256d2cb52f1cd63d9a462d5 Mon Sep 17 00:00:00 2001
From: Xavier Stevens <xavier@simple.com>
Date: Fri, 16 Jan 2015 14:43:34 -0800
Subject: [PATCH] Changed output table to only use table name and exclude the
 schema

---
 src/decoderbufs.c | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/src/decoderbufs.c b/src/decoderbufs.c
index 49cd94f..dac6321 100644
--- a/src/decoderbufs.c
+++ b/src/decoderbufs.c
@@ -417,9 +417,7 @@ static void pg_decode_change(LogicalDecodingContext *ctx, ReorderBufferTXN *txn,
   /* set common fields */
   rmsg.commit_time = TIMESTAMPTZ_TO_USEC_SINCE_EPOCH(txn->commit_time);
   rmsg.has_commit_time = true;
-  rmsg.table = quote_qualified_identifier(
-      get_namespace_name(get_rel_namespace(RelationGetRelid(relation))),
-      NameStr(class_form->relname));
+  rmsg.table = pstrdup(NameStr(class_form->relname));
 
   /* decode different operation types */
   switch (change->action) {