@@ -119,12 +119,14 @@ public static <T> Coder<T> of(
119119 @ Override
120120 public void encode (ValueInSingleWindow <T > windowedElem , OutputStream outStream )
121121 throws IOException {
122- encode (windowedElem , outStream , Coder .Context .NESTED );
122+ encode (windowedElem , outStream , org . apache . beam . sdk . coders . Coder .Context .NESTED );
123123 }
124124
125125 @ Override
126126 public void encode (
127- ValueInSingleWindow <T > windowedElem , OutputStream outStream , Coder .Context context )
127+ ValueInSingleWindow <T > windowedElem ,
128+ OutputStream outStream ,
129+ org .apache .beam .sdk .coders .Coder .Context context )
128130 throws IOException {
129131 InstantCoder .of ().encode (windowedElem .getTimestamp (), outStream );
130132 windowCoder .encode (windowedElem .getWindow (), outStream );
@@ -154,13 +156,13 @@ public void encode(
154156
155157 @ Override
156158 public ValueInSingleWindow <T > decode (InputStream inStream ) throws IOException {
157- return decode (inStream , Coder .Context .NESTED );
159+ return decode (inStream , org . apache . beam . sdk . coders . Coder .Context .NESTED );
158160 }
159161
160162 @ Override
161163 @ SuppressWarnings ("IgnoredPureGetter" )
162- public ValueInSingleWindow <T > decode (InputStream inStream , Coder . Context context )
163- throws IOException {
164+ public ValueInSingleWindow <T > decode (
165+ InputStream inStream , org . apache . beam . sdk . coders . Coder . Context context ) throws IOException {
164166 Instant timestamp = InstantCoder .of ().decode (inStream );
165167 BoundedWindow window = windowCoder .decode (inStream );
166168 PaneInfo paneInfo = PaneInfo .PaneInfoCoder .INSTANCE .decode (inStream );
0 commit comments