remove LP indicator (apache#11937)

mransley · Jun 5, 2020 · d58fb74 · d58fb74
1 parent a560ed2
commit d58fb74
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/sdks/go/pkg/beam/core/graph/coder/stringutf8.go b/sdks/go/pkg/beam/core/graph/coder/stringutf8.go
@@ -24,8 +24,8 @@ import (
 
 const bufCap = 64
 
-// EncodeStringUTF8LP encodes a UTF string with a length prefix.
-func EncodeStringUTF8LP(s string, w io.Writer) error {
+// EncodeStringUTF8 encodes a UTF8 string with a length prefix.
+func EncodeStringUTF8(s string, w io.Writer) error {
  if err := EncodeVarInt(int64(len(s)), w); err != nil {
  return err
  }
@@ -73,8 +73,8 @@ func decodeStringUTF8(l int64, r io.Reader) (string, error) {
  return builder.String(), nil
 }
 
-// DecodeStringUTF8LP decodes a length prefixed utf8 string.
-func DecodeStringUTF8LP(r io.Reader) (string, error) {
+// DecodeStringUTF8 decodes a length prefixed UTF8 string.
+func DecodeStringUTF8(r io.Reader) (string, error) {
  l, err := DecodeVarInt(r)
  if err != nil {
  return "", err

diff --git a/sdks/go/pkg/beam/core/graph/coder/stringutf8_test.go b/sdks/go/pkg/beam/core/graph/coder/stringutf8_test.go
@@ -106,11 +106,11 @@ func TestEncodeDecodeStringUTF8LP(t *testing.T) {
  want := s
  t.Run(want, func(t *testing.T) {
  var build strings.Builder
- if err := EncodeStringUTF8LP(want, &build); err != nil {
+ if err := EncodeStringUTF8(want, &build); err != nil {
  t.Fatal(err)
  }
  buf := bytes.NewBufferString(build.String())
- got, err := DecodeStringUTF8LP(buf)
+ got, err := DecodeStringUTF8(buf)
  if err != nil && err != io.EOF {
  t.Fatal(err)
  }