Read pubsub message publish time using Apache beam with Google dataflow

By -
This is a simple message to read publishTime of a message when reading using PubSub IO.

@ProcessElement
    public void processElement(DoFn<String, MessageDTO>.ProcessContext c) throws Exception {
       
        MessageDTO dataPacket = c.element();
       
        Instant time = c.timestamp();
      
        dto.setPubsubTimestamp(time.toDateTime());

        c.output(dto);
       }

Comments

Post a Comment

Popular posts from this blog

Read Images from a xlsx file using Apache POI

By -
This article is all about how to read and download images inside a file in xlsx format. We will use Apache POI using java. 1. Maven dependencies commons-logging-1.2.jar  commons-collections4-4.1.jar openxml4j-1.0-betapoi-3.16.jar poi-ooxml-3.16.jar poi-ooxml-schemas-3.16.jar xmlbeans-2.6.0.jar servlet-api 2. Sharing java code import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.util.ArrayList; import java.util.Iterator; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import org.apache.poi.ss.usermodel.PictureData; import org.apache.poi.xssf.usermodel.XSSFCell; import org.apache.poi.xssf.usermodel.XSSFDrawing; import org.apache.poi.xssf.usermodel.XSSFPicture; import org.apache.poi.xssf.usermodel.XSSFRow; import org.apache.poi.xssf.usermodel.XSSFShape; import org.apache.poi.xssf.usermodel.XSSFSheet; import
Read more

Struts 2 : Warning :No configuration found for the specified action: 'Login.action' in namespace: '/'

By -
No configuration found for the specified action: 'Login.action' in namespace: '/'''. Form action defaulting to 'action' attribute's literal value. Solution: To remove this warning you need to change following... See your struts.xml file what name you have specified... If you are using namespace / and your action name is 'Login' then  replace Login.action to Login as given below... <s:form action=" Login.action " method="post" >   Use below with namespace  1) <s:form action=" Login " method="post" namespace="/">   Or   2) <s:form action=" /Login " method="post" >   Now you will not get this warning.
Read more

How to create mail message in FRC822 format

By -
Here is the RFC822 message sample format...which is accepted by archive mail server. --------------------------------------------------------------------------------------- Date: Fri, 23 Sep 2011 11:33:37 +0530 (GMT+05:30) From:sender@gmail.com To:  archive@.............archive.psmtp.com Cc:  archive@.............archive.psmtp.com Message-ID: <18916478.4.1316757817734.JavaMail.user@NIC-TestUser> Subject: Test E-Mail through Java MIME-Version: 1.0 Content-Type: multipart/mixed;     boundary="----=_Part_3_16554308.1316757817718" ------=_Part_3_16554308.1316757817718 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: 7bit This is part one of a test multipart e-mail.The second part is file as an attachment ------=_Part_3_16554308.1316757817718 Content-Type: text/plain; charset=us-ascii; name=testfile.txt Content-Transfer-Encoding: 7bit Content-Disposition: attachment; filename=testfile.txt Hi, This is a test file. ------=_Part_3_16554308.1316757817718-
Read more