在Dataflow Generic中进行转换

这与另一个SO问题[此处]( 设置自定义编码器和处理参数化类型 )有关。在解决方法之后,帮助我在变换中使用自定义类型。 但由于我的自定义类型是通用的,我希望甚至使变换类通用,然后可以使用相同的类型参数化自定义类型。 但是当我尝试这样做时,我遇到了无法为类型变量T提供编码器,因为实际类型由于擦除而未知 。 解决方案建议注册一个可以返回类型参数的编码器,但由于类型参数本身是未知的,我想这个exception会抛出,我不知道如何解决这个问题。 static class Processor extends PTransform<PCollection, PCollection<KV<String, Set<CustomType>>>> { private static final long serialVersionUID = 0; @Override public PCollection<KV<String, Set<CustomType>>> apply(PCollection items) { PCollection<KV<String, Set<CustomType>>> partitionedItems = items .apply(ParDo.of(new ParDoFn())); PCollection<KV<String, Set<CustomType>>> combinedItems = partitionedItems .apply(Combine.<String, Set<CustomType>>perKey(new Merger())); } }

Org.hibernate.HibernateException:没有活动事务,createQuery无效

在这个问题之后 ,我试图将Hibernate 4.3.8.Final添加到Spring 4.1.5.RELEASE; 但是 – 代码抛出一个exception,因为跟随并且有时抛出 – 它无法找到hibernate的实体类(com.myproject.model.MyTable),尽管该类存在且位于com.myproject.model包中。 堆栈跟踪 org.hibernate.HibernateException: createQuery is not valid without active transaction at org.hibernate.context.internal.ThreadLocalSessionContext$TransactionProtectionWrapper.invoke(ThreadLocalSessionContext.java:352) at com.sun.proxy.$Proxy40.createQuery(Unknown Source) at com.myproject.repository.TestRepImpl.get(TestRepImpl.java:21) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:483) at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:317) at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:190) at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157) at org.springframework.dao.support.PersistenceExceptionTranslationInterceptor.invoke(PersistenceExceptionTranslationInterceptor.java:136) at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179) at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:207) at com.sun.proxy.$Proxy33.get(Unknown Source) at com.myproject.service.TestServiceImpl.get(TestServiceImpl.java:17) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at […]

隐藏或删除特定活动的操作栏 Android的

如何删除不针对所有应用程序的特定活动的操作栏,例如我有注册活动,对于此活动,我想删除操作栏

折线不显示在2个位置之间,但显示时间和距离

注意:抱歉我的英语不好,因为英语不是我的母语,我使用谷歌翻译。 我正在开发一个Android地图应用,用户可以在其中找到朋友的当前位置。 为了存储当前位置,我正在使用Firebase实时数据库。 在Lalit Singh之前的帮助下,它现在显示时间和距离,但仍未在两个不同的地方更新Polylines。 我的更新代码如下。 mapsActivity.java(我从火基地获取朋友位置,并更新时间,距离和折线方法) public void proceed(final View view) { DatabaseReference ref = FirebaseDatabase.getInstance().getReference().child(“Email”); ref.addValueEventListener(new ValueEventListener() { @Override public void onDataChange(DataSnapshot dataSnapshot) { for (DataSnapshot dataSnapshot1 : dataSnapshot.getChildren()) { UserInformation details = dataSnapshot1.getValue(UserInformation.class); if (mMap != null) { mMap.clear(); } MarkerOptions markerOptions = new MarkerOptions(); LatLng latLng1 = new LatLng(details.getLatitude(), details.getLongitude()); markerOptions.position(latLng1); […]

如何将n个列导出为Java中的PDF标题?

任何人都可以告诉我如何导出n个列作为Java中PDF的标题? 实际上用户以CSV格式上传文件。 我需要将该文件导出为PDF。 问题是如果CSV文件有1000列作为标题,那么在导出为PDF时如何处理。 编辑:是的我问如何实现布局,意味着我们不能将所有1000列作为标题放在一个页面中…我们可以为pdf页面添加滚动条吗? Edit2:我正在使用itext进行pdf生成。 如何找到最大超限。 如果发生水平滚动没问题。 行也将成千上万。 在这里我可以生成pdf文件,但如果它超过8或10,那么列就会混合在一起,以避免我如何生成水平卷轴?

如何将JFXPanel添加到现有的swing应用程序中

我非常想知道如何将我的JFXPanel(这是一个mp3播放器)集成到现有的Swing应用程序中 – 这是一个添加了几个不同JPanel的JFrame。 我是JavaFX的完全菜鸟,它与swing非常不同。 我能够得到下面的代码来运行并做我想要的。 它将播放我所包含的目录中的mp3文件。这是来自某人编写的样本的代码。 我的问题是这段代码创建了JFrame,主要方法以及此代码中的所有内容。 我有一个已经制作的swing应用程序,我只想添加一个具有以下function的JFXPanel。 JavaFX中有许多新方法我很困惑,不知道如何使用或放在我的Swing应用程序中。 例如invokeLater runLater和initAndShowGUI。 我知道这可能是一个令人烦恼的问题,很难从这样的菜鸟那里回答。 我有一个项目将于明天晚上午夜到期,我真的希望将其作为应用程序的一部分实现。 我们没有在课堂上学习JavaFX,我不知道这对我来说是个棘手的问题。 package application; import java.io.*; import java.util.*; import javafx.application.Platform; import javafx.beans.value.*; import javafx.embed.swing.JFXPanel; import javafx.event.*; import javafx.geometry.Pos; import javafx.scene.Scene; import javafx.scene.control.*; import javafx.scene.layout.*; import javafx.scene.media.*; import javafx.util.Duration; import javax.swing.*; /** Example of playing all mp3 audio files in a given directory * […]

如何将参数发送到流中的引用方法(java 8)?

我有一个活动列表(活动),我想确定一个Map(String, DateTime)的表格Map(String, DateTime) (不是Duration或Period;它是必须的Map(String, DateTime)的数据结构。 对于每个活动,在监测期间计算的总持续时间。 Activity类有: activityLabel(String) , startTime(DateTime) , endTime(DateTime) 。 我用joda时间。 这就是我所做的: Map durations = activities.stream().collect(Collectors.toMap( it -> it.activityLabel, it ->new DateTime(0,0,0,0,0,0) //,DateTime::plus )); 我想我应该使用DateTime plus(ReadablePeriod period)或DateTime plus(ReadableDuration duration) ,但我不知道如何将类型为Duration或Period的参数发送到方法引用。 我怎样才能达到这个效果? 编辑:输入: 2011-12-03 01:00:00 2011-12-03 9:00:00睡觉 2011-12-04 03:00:00 2011-12-04 10:30:00睡觉 我应该有输出:睡觉0-0-0 15:30:00(年,月,日,小时,分钟,秒)

用于确定两个arraylist中不同项目的代码

我有两个arraylist,定义如下。 ArrayList list1 = new arrayList(); ArrayList list2 = new arrayList(); list1.add(“sultan”); list1.add(“Masum”); list1.add(“sultan”); list1.add(“Sorry”); list1.add(“sultan”); list1.add(“Masum”); list1.add(“sultan”); list1.add(“Tarek”); list1.add(“sultan”); list2.add(“Billal”); list2.add(“Masum”); list2.add(“Sorry”); list2.add(“Sorry”); list2.add(“sultan”); list2.add(“Masum”); list2.add(“Tanha”); list2.add(“Tarek”); list2.add(“Die”); 我想知道上面两个arraylist中不同的项目。 为此,我有以下一段代码。 int count=0; for(String s1:list1) { if(!list2.contains(s1)) ++count; } for(String s2:list2) { if(!list1.contains(s2)) ++count; } 但是我的代码非常低效。 你能告诉我一个更好的方法来实现我的目的吗?

从Java应用程序中执行Pig

是否可以在Java应用程序中运行Apache Pig作业,而不需要外部进程? 似乎Pig和Hadoop都是用Java编写的,但并不真正提供Java API。 我宁愿在Java Spring应用程序中使用这些工具表单,而不是依赖shell脚本。

Camel + Jackson:为所有反序列化注册一个模块

我正在使用Camel作为我的应用程序,消息作为JSON进入路由。 我使用JACKSON作为我的反序列化器。 我有一个案例,我需要一个自定义序列化器/反序列化器来处理我的一条消息。 我想要做的是为键注册自定义序列化器/解串器。 在Camel中,如何在我的路线中编组/取消编组时,如何确保序列化器/解串器可用?